Platform Explorer / Nuxeo Platform LTS 2019 10.10

Extension point streamProcessor

In component org.nuxeo.runtime.stream.service

Contribution Descriptors

  • Class: org.nuxeo.runtime.stream.StreamProcessorDescriptor

Existing Contributions

Contributions are presented in the same order as the registration order on this extension point. This order is displayed before the contribution name, in brackets.

  • nuxeo-core-10.10-HF32.jar /OSGI-INF/retention-and-hold-contrib.xml 
    <extension point="streamProcessor" target="org.nuxeo.runtime.stream.service">
    <streamProcessor class="org.nuxeo.ecm.core.security.RetentionExpiredAction" defaultConcurrency="1" defaultPartitions="1" logConfig="bulk" name="retentionExpired">
      <!-- continue on failure, because failure to expire retention doesn't give us an inconsistent state -->
      <policy continueOnFailure="true" delay="1s" maxDelay="60s" maxRetries="20" name="default"/>
    </streamProcessor>
  </extension>
    (0) nuxeo-core-10.10-HF32.jar/OSGI-INF/retention-and-hold-contrib.xml   Override
  • nuxeo-platform-csv-export-10.10-HF21.jar /OSGI-INF/csv-export-config.xml 
    <extension point="streamProcessor" target="org.nuxeo.runtime.stream.service">
    <!-- CSV exporter processor -->
    <streamProcessor class="org.nuxeo.ecm.platform.csv.export.action.CSVExportAction" defaultConcurrency="2" defaultPartitions="2" logConfig="bulk" name="csvExport">
      <policy continueOnFailure="true" delay="1s" maxDelay="10s" maxRetries="3" name="default"/>
      <option name="produceImmediate">false</option>
    </streamProcessor>
  </extension>
    (1) nuxeo-platform-csv-export-10.10-HF21.jar/OSGI-INF/csv-export-config.xml   Override
  • nuxeo-platform-imaging-core-10.10-HF21.jar /OSGI-INF/imaging-bulk-contrib.xml 
    <extension point="streamProcessor" target="org.nuxeo.runtime.stream.service">
    <streamProcessor class="org.nuxeo.ecm.platform.picture.recompute.RecomputeViewsAction" defaultConcurrency="2" defaultPartitions="2" logConfig="bulk" name="recomputeViews">
      <policy continueOnFailure="true" delay="1s" maxDelay="10s" maxRetries="3" name="default"/>
      <option name="produceImmediate">false</option>
    </streamProcessor>
  </extension>
    (2) nuxeo-platform-imaging-core-10.10-HF21.jar/OSGI-INF/imaging-bulk-contrib.xml   Override
  • nuxeo-platform-audit-core-10.10-HF33.jar /OSGI-INF/nxaudit-service.xml 
    <extension point="streamProcessor" target="org.nuxeo.runtime.stream.service">
    <streamProcessor class="org.nuxeo.ecm.platform.audit.impl.StreamAuditWriter" defaultCodec="legacy" defaultConcurrency="1" defaultPartitions="1" enabled="true" logConfig="audit" name="auditLogWriter">
      <policy batchCapacity="25" batchThreshold="500ms" continueOnFailure="false" delay="1s" maxDelay="60s" maxRetries="20" name="AuditLogWriter"/>
    </streamProcessor>
  </extension>
    (3) nuxeo-platform-audit-core-10.10-HF33.jar/OSGI-INF/nxaudit-service.xml   Override
  • nuxeo-core-bulk-10.10-HF33.jar /OSGI-INF/bulk-config.xml 
    <extension point="streamProcessor" target="org.nuxeo.runtime.stream.service">
    <!-- SetProperty processor -->
    <streamProcessor class="org.nuxeo.ecm.core.bulk.action.SetPropertiesAction" defaultConcurrency="2" defaultPartitions="2" logConfig="bulk" name="setProperties">
      <policy continueOnFailure="false" delay="500ms" maxDelay="10s" maxRetries="3" name="default"/>
    </streamProcessor>

    <!-- SetSystemProperty processor -->
    <streamProcessor class="org.nuxeo.ecm.core.bulk.action.SetSystemPropertiesAction" defaultConcurrency="2" defaultPartitions="2" logConfig="bulk" name="setSystemProperties">
      <policy continueOnFailure="false" delay="500ms" maxDelay="10s" maxRetries="3" name="default"/>
    </streamProcessor>

    <!-- RemoveProxy processor -->
    <streamProcessor class="org.nuxeo.ecm.core.bulk.action.RemoveProxyAction" defaultConcurrency="2" defaultPartitions="2" logConfig="bulk" name="removeProxy">
      <policy continueOnFailure="false" delay="500ms" maxDelay="10s" maxRetries="3" name="default"/>
    </streamProcessor>

    <!-- Trash processor -->
    <streamProcessor class="org.nuxeo.ecm.core.bulk.action.TrashAction" defaultConcurrency="1" defaultPartitions="1" logConfig="bulk" name="trash">
      <policy continueOnFailure="false" delay="500ms" maxDelay="10s" maxRetries="3" name="default"/>
    </streamProcessor>

  </extension>
    (4) nuxeo-core-bulk-10.10-HF33.jar/OSGI-INF/bulk-config.xml   Override
  • nuxeo-automation-features-10.10-HF28.jar /OSGI-INF/bulk-contrib.xml 
    <extension point="streamProcessor" target="org.nuxeo.runtime.stream.service">
    <streamProcessor class="org.nuxeo.ecm.automation.core.operations.services.bulk.AutomationBulkAction" defaultConcurrency="2" defaultPartitions="2" logConfig="bulk" name="automation">
      <policy continueOnFailure="true" delay="1s" maxRetries="3" name="automation"/>
    </streamProcessor>
  </extension>
    (5) nuxeo-automation-features-10.10-HF28.jar/OSGI-INF/bulk-contrib.xml   Override
  • nuxeo-elasticsearch-core-10.10-HF32.jar /OSGI-INF/bulk-contrib.xml 
    <extension point="streamProcessor" target="org.nuxeo.runtime.stream.service">
    <streamProcessor class="org.nuxeo.elasticsearch.bulk.IndexAction" defaultConcurrency="2" defaultPartitions="4" enabled="true" logConfig="bulk" name="reindex">
      <policy continueOnFailure="false" delay="1s" maxDelay="60s" maxRetries="20" name="default"/>
      <!-- concurrency to build indexing requests -->
      <computation concurrency="2" name="index"/>
      <!-- concurrency to execute indexing requests -->
      <computation concurrency="2" name="bulkIndex"/>
      <computation concurrency="1" name="indexCompletion"/>
      <!-- optimal size of the elasticsearch bulk request -->
      <option name="esBulkSizeBytes">5242880</option>
      <!-- max number of actions in the elasticsearch bulk request -->
      <option name="esBulkActions">1000</option>
      <!-- flush elasticsearch bulk request interval -->
      <option name="flushIntervalSeconds">5</option>
    </streamProcessor>

  </extension>
    (6) nuxeo-elasticsearch-core-10.10-HF32.jar/OSGI-INF/bulk-contrib.xml   Override
  • nuxeo-thumbnail-10.10-HF18.jar /OSGI-INF/thumbnail-bulk-contrib.xml 
    <extension point="streamProcessor" target="org.nuxeo.runtime.stream.service">
    <streamProcessor class="org.nuxeo.ecm.platform.thumbnail.action.RecomputeThumbnailsAction" defaultConcurrency="2" defaultPartitions="2" logConfig="bulk" name="recomputeThumbnails">
      <policy continueOnFailure="true" delay="1s" maxDelay="10s" maxRetries="3" name="default"/>
      <option name="produceImmediate">false</option>
    </streamProcessor>
  </extension>
    (7) nuxeo-thumbnail-10.10-HF18.jar/OSGI-INF/thumbnail-bulk-contrib.xml   Override